package com.mo.axion.stream.constants;

import lombok.NoArgsConstructor;

/**
 * @author Mo
 * @createTime 2024/4/13 17:38
 * @description Flink常量信息
 */
@NoArgsConstructor
public class AxionFlinkConstant {
    /**
     * Kafka常量
     */
    public static final String GROUP_ID = "axionLogGroup";
    public static final String TOPIC_NAME = "axionTraceLog";
    public static final String BROKER = "8.134.210.27:9092";

    /**
     * redis常量
     */
    public static final String REDIS_IP = "8.134.210.27";
    public static final String REDIS_PORT = "6379";
    public static final String REDIS_PASSWORD = "axion";

    /**
     * Flink常量
     */
    public static final String SOURCE_NAME = "axion_kafka_source";
    public static final String FUNCTION_NAME = "axion_transfer";
    public static final String SINK_NAME = "axion_sink";
    public static final String JOB_NAME = "AxionBootStrap";

}
